package main

import (
	"crontab/common"
	"crontab/master"
	"crontab/worker"
	"flag"
	"runtime"
	"time"
)

// 配置文件路径
var conf string

// 初始化线程数量
func initEnv() {
	runtime.GOMAXPROCS(runtime.NumCPU())
}

// 解析命令行参数
func initArgs() {
	flag.StringVar(&conf, "config", "./worker.json", "指定worker.json")
	flag.Parse()
}

func main() {
	initArgs()
	initEnv()
	err := worker.InitConfig(conf)
	common.DealError("config", err)
	err = worker.InitScheduler()
	common.DealError("config", err)
	worker.InitJobMgr()
	err = master.InitApiServer()
	common.DealError("server", err)
	for {
		time.Sleep(1 * time.Second)
	}
}
